package com.workcell.workdata.xthings.kafka.content;

import org.apache.kafka.clients.consumer.ConsumerRecord;

import java.util.Objects;

/**
 * @Author 廖博文
 * @Date 2023/5/25 12:03
 * @Description
 */
public interface MqService {

	/**
	 * 消费队列的消息
	 */
	void handlerKafkaMessage(ConsumerRecord<Object, Objects> consumerRecord);

}
